//package io.xiyou.user.listener;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Component;
//
///**
// * @ClassName：KafkaMessageListener
// * @Author：西柚
// * @Date：2021/11/3 10:46 上午
// * @Versiion：1.0
// */
//@Slf4j
//@Component
//public class KafkaMessageListener {
//
//    @KafkaListener(topics = "${spring.kafka.topic-name}", groupId = "${spring.kafka.consumer.group-id}")
//    public void listen(String message) {
//        log.info("接收消息: {}", message);
//    }
//
//}
